package com.suning.framework.ImportMpsInfo;

import com.suning.framework.Dao;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * 〈一句话功能简述〉<br>
 * 〈功能详细描述〉
 *
 * @author 16080951(林健)
 * @Copyright (c) 2016 苏宁软件技术有限公司 版权所有
 * @see [相关类/方法]（可选）
 * @since [产品/模块版本] （可选）
 */
public class TheadPoolTest {

    //每页10000条处理。
    private int pageSize = 10000;

    //共多少条
    private Long totalCount = 0L;

    //共多少页
    private Long totalPage = 0L;


    private void run(){

        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("config/application.xml");
        //获取dao
        Dao dao = (Dao) applicationContext.getBean("dao");

        //查询总量
        totalCount = dao.getCount();

        //共多少页
        totalPage = totalCount % pageSize == 0 ? totalCount / pageSize : ((totalCount / pageSize) + 1);
        //totalPage = 20L;

        for(int i = 0;i<totalPage;i++) {

            //计算分页数据
            TestRunnable testRunnable = new TestRunnable();
            testRunnable.setStartPage(i * pageSize);
            testRunnable.setEndPage((i+1) * pageSize);
            //加入线程池处理
            ThreadPool.execute(testRunnable);
        }

    }

    public static void main(String[] args) {

        TheadPoolTest theadPoolTest = new TheadPoolTest();
        //导入数据
        theadPoolTest.run();
    }
}
